package flinkdemo.faceSink;


import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.util.Collector;

public class DebugFlatMap implements FlatMapFunction<ImageData, IdLabel> {

    public DebugFlatMap() {
    }


    @Override
    public void flatMap(ImageData value, Collector<IdLabel> out) throws Exception {
        IdLabel idLabel = new IdLabel();
        idLabel.setId(value.getId());
        out.collect(idLabel);
    }
}
